package com.storm.queue

import com.fasterxml.jackson.databind.ObjectMapper
import com.storm.queue.core.DelayOperation
import com.storm.queue.model.Job
import org.springframework.data.redis.core.RedisTemplate

class QueueApi(private val operation: DelayOperation) {

    fun addJob(job: Job, topic: String, limitTime: Long) {
        operation.addJob(job, topic, limitTime)
    }

    fun delJob(topic: String, id: String) {
        operation.deleteJob(topic, id)
    }
}